import java.io.*;
import java.text.*;
import java.util.*;
import javax.mail.*;
import javax.mail.internet.*;



public class ParseMimeMessage
{
private MimeMessage mimeMessage = null;
private String saveAttachPath = ""; // 附件下载后的存放目录
private StringBuffer bodytext = new StringBuffer(); // 存放邮件内容的StringBuffer对象
private String dateformat = "yyyy-MM-dd HH:mm"; // 默认的日前显示格式
public  static int totalbytes=0;
public  static int  nowbytes=0;


/**
* 构造函数,初始化一个MimeMessage对象
*/
public ParseMimeMessage()
{}
public ParseMimeMessage(MimeMessage mimeMessage)
{
   this.mimeMessage = mimeMessage;
   //System.out.println("create a ParseMimeMessage object........");
}

public void setMimeMessage(MimeMessage mimeMessage)
{
   this.mimeMessage = mimeMessage;
}

/**
* 获得发件人的地址和姓名
*/
public String getFrom() throws Exception
{
   InternetAddress address[] = (InternetAddress[]) mimeMessage.getFrom();
   String from = address[0].getAddress();
   if (from == null)
    from = "";
   String personal = address[0].getPersonal();
   if (personal == null)
    personal = "";
   String fromaddr = personal + "<" + from + ">";
   return fromaddr;
}

/**
* 获得邮件的收件人，抄送，和密送的地址和姓名，根据所传递的参数的不同 "to"----收件人 "cc"---抄送人地址 "bcc"---密送人地址
*/
public String getMailAddress(String type) throws Exception
{
   String mailaddr = "";
   String addtype = type.toUpperCase();
   InternetAddress[] address = null;
   if (addtype.equals("TO") || addtype.equals("CC")
     || addtype.equals("BCC"))
   {
    if (addtype.equals("TO"))
    {
     address = (InternetAddress[]) mimeMessage
       .getRecipients(Message.RecipientType.TO);
    } else if (addtype.equals("CC"))
    {
     address = (InternetAddress[]) mimeMessage
       .getRecipients(Message.RecipientType.CC);
    } else
    {
     address = (InternetAddress[]) mimeMessage
       .getRecipients(Message.RecipientType.BCC);
    }
   
    if (address != null)
    {
     for (int i = 0; i < address.length; i++)
     {
      String email = address[i].getAddress();
     
      if (email == null)
       email = "";
      else
      {
       email = MimeUtility.decodeText(email);
      }
      String personal = address[i].getPersonal();
     
      if (personal == null)
       personal = "";
      else
      {
       personal = MimeUtility.decodeText(personal);
      }
      String compositeto = personal + "<" + email + ">";
      mailaddr += "," + compositeto;
     }
     mailaddr = mailaddr.substring(1);
    }
   } else
   {
    throw new Exception("Error emailaddr type!");
   }
   return mailaddr;
}

/**
* 获得邮件主题
*/
public String getSubject() throws MessagingException
{
   String subject = "";
   try
   {
    subject = MimeUtility.decodeText(mimeMessage.getSubject());
    if (subject == null)
     subject = "";
   } catch (Exception exce)
   {}
   return subject;
}

/**
* 获得邮件发送日期
*/
public String getSentDate() throws Exception
{
   Date sentdate = mimeMessage.getSentDate();
   SimpleDateFormat format = new SimpleDateFormat(dateformat);
   return format.format(sentdate);
}

/**
* 获得邮件正文内容
*/
public String getBodyText()
{
   return bodytext.toString();
}

/**
* 解析邮件，把得到的邮件内容保存到一个StringBuffer对象中，解析邮件 主要是根据MimeType类型的不同执行不同的操作，一步一步的解析
*/
public void getMailContent(Part part) throws Exception
{
   String contenttype = part.getContentType();
   int nameindex = contenttype.indexOf("name");
   boolean conname = false;
   if (nameindex != -1)
    conname = true;

   System.out.println("CONTENTTYPE: " + contenttype);
   if (part.isMimeType("text/plain") && !conname)
   {
    bodytext.append((String) part.getContent());
   } else if (part.isMimeType("text/html") && !conname)
   {
    bodytext.append((String) part.getContent());
   } else if (part.isMimeType("multipart/*"))
   {
    Multipart multipart = (Multipart) part.getContent();
    int counts = multipart.getCount();
    for (int i = 0; i < counts; i++)
    {
     getMailContent(multipart.getBodyPart(i));
    }
   } else if (part.isMimeType("message/rfc822"))
   {
    getMailContent((Part) part.getContent());
   } else
   {}
}

/**
* 判断此邮件是否需要回执，如果需要回执返回"true",否则返回"false"
*/
public boolean getReplySign() throws MessagingException
{
   boolean replysign = false;
   String needreply[] = mimeMessage
     .getHeader("Disposition-Notification-To");
   if (needreply != null)
   {
    replysign = true;
   }
   return replysign;
}

/**
* 获得此邮件的Message-ID
*/
public String getMessageId() throws MessagingException
{
   return mimeMessage.getMessageID();
}

/**
* 判断此邮件是否已读，如果未读返回返回false,反之返回true
*/
public boolean isNew() throws MessagingException
{
   boolean isnew = false;
   Flags flags = ((Message) mimeMessage).getFlags();
   Flags.Flag[] flag = flags.getSystemFlags();
   System.out.println("flags's length: " + flag.length);
   for (int i = 0; i < flag.length; i++)
   {
    if (flag[i] == Flags.Flag.SEEN)
    {
     isnew = true;
     System.out.println("seen Message.......");
     break;
    }
   }
   return isnew;
}

/**
* 判断此邮件是否包含附件
*/
public boolean isContainAttach(Part part) throws Exception
{
   boolean attachflag = false;
   String contentType = part.getContentType();
   if (part.isMimeType("multipart/*"))
   {
    Multipart mp = (Multipart) part.getContent();
    for (int i = 0; i < mp.getCount(); i++)
    {
     BodyPart mpart = mp.getBodyPart(i);
     String disposition = mpart.getDisposition();
     if ((disposition != null)
       && ((disposition.equals(Part.ATTACHMENT)) || (disposition
         .equals(Part.INLINE))))
      attachflag = true;
     else if (mpart.isMimeType("multipart/*"))
     {
      attachflag = isContainAttach((Part) mpart);
     } else
     {
      String contype = mpart.getContentType();
      if (contype.toLowerCase().indexOf("application") != -1)
       attachflag = true;
      if (contype.toLowerCase().indexOf("name") != -1)
       attachflag = true;
     }
    }
   } else if (part.isMimeType("message/rfc822"))
   {
    attachflag = isContainAttach((Part) part.getContent());
   }
   return attachflag;
}

/**
* 保存附件
*/
public void saveAttachMent(Part part) throws Exception
{
   String fileName = "";
   if (part.isMimeType("multipart/*"))
   {
    Multipart mp = (Multipart) part.getContent();
    for (int i = 0; i < mp.getCount(); i++)
    {
     BodyPart mpart = mp.getBodyPart(i);
     String disposition = mpart.getDisposition();
     //System.out.println(disposition);
     
     if ((disposition != null)
       && (disposition.equals(Part.ATTACHMENT)))
     {
      fileName = mpart.getFileName();
      
     //System.out.println(fileName);
      
    if (fileName.toLowerCase().indexOf("gb2312") != -1||fileName.toLowerCase().indexOf("gbk") != -1)
     {
      fileName = MimeUtility.decodeText(fileName);
     }
      saveFile(fileName, mpart.getInputStream());
      
      //saveFile("nihao.txt", mpart.getInputStream());
     } else if (mpart.isMimeType("multipart/*"))
     {
      saveAttachMent(mpart);
     } else
     {
      fileName = mpart.getFileName();
      if ((fileName != null)
        && (fileName.toLowerCase().indexOf("GB2312") != -1))
      {
       fileName = MimeUtility.decodeText(fileName);
       saveFile(fileName, mpart.getInputStream());
      }
     }
    }
   } else if (part.isMimeType("message/rfc822"))
   {
    saveAttachMent((Part) part.getContent());
   }
}

/**
* 设置附件存放路径
*/
public void setAttachPath(String attachpath)
{
   this.saveAttachPath = attachpath;
}

/**
* 设置日期显示格式
*/
public void setDateFormat(String format) throws Exception
{
   this.dateformat = format;
}

/**
* 获得附件存放路径
*/
public String getAttachPath()
{
   return saveAttachPath;
}

/**
* 真正的保存附件到指定目录里
*/
private void saveFile(String fileName, InputStream in) throws Exception
{
	totalbytes=0;
	nowbytes=0;
	
   String osName = System.getProperty("os.name");
   String storedir = getAttachPath();
   String separator = "";
   if (osName == null)
    osName = "";
   if (osName.toLowerCase().indexOf("win") != -1)
   {
    separator = "\\";
    if (storedir == null || storedir.equals(""))
     storedir = "c:\\tmp";
   } else
   {
    separator = "/";
    storedir = "/tmp";
   }
   File storefile = new File(storedir + separator + fileName);
   System.out.println("storefile's path: " + storefile.toString());
   // for(int i=0;storefile.exists();i++){
   // storefile = new File(storedir+separator+fileName+i);
   // }
   BufferedOutputStream bos = null;
   BufferedInputStream bis = null;
   try
   {
    bos = new BufferedOutputStream(new FileOutputStream(storefile));
    bis = new BufferedInputStream(in);
    int c;
    while ((c = bis.read()) != -1)
    {
     bos.write(c);
     bos.flush();
    }
   } catch (Exception exception)
   {
    exception.printStackTrace();
    throw new Exception("文件保存失败!");
   } finally
   {
    bos.close();
    bis.close();
   }
}

   


/**
* ParseMimeMessage类测试
*/
public  void  download(int x,String path) throws Exception
{
   String host = "pop.sina.com.cn"; // 【pop.mail.yahoo.com.cn】
   String username = "wangq_30"; // 【wwp_1124】
   String password = "901170"; // 【........】
   int flag=0;
  
   Properties props = new Properties();
   Session session = Session.getDefaultInstance(props, null);
   Store store = session.getStore("pop3");
  
   store.connect(host, username, password);//??????????
   
   
   Folder folder = store.getFolder("INBOX");
   folder.open(Folder.READ_ONLY);
   Message message[] = folder.getMessages();
   System.out.println("Messages's length: " + message.length);
   ParseMimeMessage pmm = null;
 //  for (int i = 0; i < message.length; i++)
  // {
	  // flag=0;
    pmm = new ParseMimeMessage((MimeMessage) message[x]);
   // System.out
    //  .println("Message " + i + " subject: " + pmm.getSubject());
    //System.out.println("Message " + i + " sentdate: "
     // + pmm.getSentDate());
    //String subject=pmm.getSubject();
    //for(int j=0;j<subject.length();j++)
   // {
   // if(subject.charAt(j)=='/')
    //	{flag=1;break;}
  //  }
   // 
   // if(flag==0)
    //	;//标题不符合要求的邮件不进行处理
    //else
    //{
    	//对邮件标题进行解析
    	
   // }
   // System.out.println("Message " + i + " replysign: "
    //  + pmm.getReplySign());
    //System.out.println("Message " + i + " hasRead: " + pmm.isNew());
    //System.out.println("Message " + i + " containAttachment: "
     // + pmm.isContainAttach((Part) message[i]));
    //System.out.println("Message " + i + " form: " + pmm.getFrom());
  //  System.out.println("Message " + i + " to: "
    //  + pmm.getMailAddress("to"));
   // System.out.println("Message " + i + " cc: "
     // + pmm.getMailAddress("cc"));
    //System.out.println("Message " + i + " bcc: "
    //  + pmm.getMailAddress("bcc"));
   // pmm.setDateFormat("yy年MM月dd日 HH:mm");
    //System.out.println("Message " + i + " sentdate: "
    //  + pmm.getSentDate());
    //System.out.println("Message " + i + " Message-ID: "
    //  + pmm.getMessageId());
    //pmm.getMailContent((Part) message[i]);
    //System.out.println("Message " + i + " bodycontent: \r\n"
     // + pmm.getBodyText());
   pmm.setAttachPath(path);
   pmm.saveAttachMent((Part) message[x]);
  // }
   folder.close(true);
   store.close();
}


public static void main (String args[])throws Exception
{
	
	
	//创建文件name.txt，存放每封邮件的标题以及上传日期
	
	File file2=new File("name.txt");
	file2.delete();
	File file=new File("name.txt");
	PrintWriter pw = new PrintWriter(new FileOutputStream(file, true), true); 
	String host = "pop.sina.com.cn"; // pop服务器：pop.sina.com.cn
	   String username = "wangq_30"; // 用户名：wangq_30
	   String password = "901170"; //password
	   int flag=0;
	  
	   Properties props = new Properties();
	   Session session = Session.getDefaultInstance(props, null);
	   Store store = session.getStore("pop3");
	  
	   store.connect(host, username, password);//建立连接
	   
	   
	   Folder folder = store.getFolder("INBOX");
	   folder.open(Folder.READ_ONLY);
	   //获得邮件对象Message
	   Message message[] = folder.getMessages();
	   System.out.println("Messages's length: " + message.length);
	   ParseMimeMessage pmm = null;
	  for (int i = 0; i < message.length; i++)
	   {
	    pmm = new ParseMimeMessage((MimeMessage) message[i]);
	    //将获得的邮件标题和邮件发送日期写入文件，并用;作为分隔符
	    pw.println(pmm.getSubject()+";"+pmm.getSentDate());

	   }
	  pw.close();
	   folder.close(true);
	   store.close();
	   System.out.println("over!");
}
}
